/*
 * Copyright (C) 2021, All rights Reserved, Designed By
 * @author: maoyz
 * @Copyright: 2021-02-24 10:17  Inc. All rights reserved.
 */
package com.myz.cloud.stream.rocketmq.header.channel;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author maoyz
 */
public interface IHeaderMessageChannel {

    String HEADER_INPUT = "header-input";

    String HEADER_OUTPUT = "header-output";

    @Input(HEADER_INPUT)
    SubscribableChannel headerInput();

    @Output(HEADER_OUTPUT)
    SubscribableChannel headerOutput();
}